package com.suddev.bigdata.utils

import org.apache.spark.rdd.RDD

/**
  *
  * @author Rand
  * @date 2019/9/28 0028
  */
object ImplicitAspect {
  class MyRdd[T](rdd: RDD[T]){
    def printInfo(flag:Int=1): RDD[T] ={
      if (flag==1) {
        rdd.collect.foreach(println)
        println("-------------------------------")
      } else if (flag == 0) {
        rdd.collect
      }
      rdd
    }
  }
  implicit def RDD2MyRDD[T](rdd: RDD[T]):MyRdd[T] = new MyRdd(rdd)
}
